package com.hoveagle.kafka.handler;

import org.apache.kafka.clients.consumer.ConsumerRecord;

/**
 * define an interface for message handler template
 * @author hoveagle
 */
public interface MessageHandler<K,V> {
     void onMessage(ConsumerRecord<K, V> consumerRecord);
}
